package com.yeyks.util;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.yeyks.base.Arguments;
import com.yeyks.wxpay.impl.MyConfig;
import com.github.binarywang.wxpay.service.WxPayService;
import org.springframework.util.StringUtils;

import javax.servlet.http.HttpServletRequest;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.math.BigInteger;
import java.net.URL;
import java.net.URLConnection;
import java.security.SecureRandom;
import java.util.*;

public class Utility {

    public static String setExtraInfo(String extraInfo, String key, Object value) {
        try {
            JSONObject jsonObject = (JSONObject) JSON.parse(extraInfo);
            jsonObject.put(key, value);
            return jsonObject.toJSONString();
        } catch (Throwable e) {
            JSONObject jsonObject = new JSONObject();
            jsonObject.put(key, value);
            return jsonObject.toJSONString();
        }
    }

    public static JSONObject toJsonObject(String extraInfo) {
        try {
            JSONObject jo =  (JSONObject) JSON.parse(extraInfo);
            if (jo == null) {
                return new JSONObject();
            } else {
                return jo;
            }
        } catch (Throwable e) {
            return new JSONObject();
        }
    }
    public static String addExtraInfoArray(String extraInfo, String key, Object value) {
        try {
            JSONObject jsonObject = (JSONObject) JSON.parse(extraInfo);

            JSONArray jsonArray;
            try {
                jsonArray = (JSONArray) jsonObject.get(key);
                if (jsonArray == null) {
                    jsonArray = new JSONArray();
                }
            } catch (Throwable e) {
                jsonArray = new JSONArray();
            }

            jsonArray.add(value);
            jsonObject.put(key, jsonArray);
            return jsonObject.toJSONString();
        } catch (Throwable e) {
            JSONObject jsonObject = new JSONObject();

            JSONArray jsonArray;
            try {
                jsonArray = (JSONArray) jsonObject.get(key);
                if (jsonArray == null) {
                    jsonArray = new JSONArray();
                }
            } catch (Throwable e2) {
                jsonArray = new JSONArray();
            }

            jsonArray.add(value);
            jsonObject.put(key, value);
            return jsonObject.toJSONString();
        }
    }
    public static String addExtraInfoMap(String extraInfo, String cata, String key, Object value) {
        try {
            JSONObject jsonObject = (JSONObject) JSON.parse(extraInfo);

            JSONObject cataObject;
            try {
                cataObject = (JSONObject) jsonObject.get(cata);
                if (cataObject == null) {
                    cataObject = new JSONObject();
                }
            } catch (Throwable e) {
                cataObject = new JSONObject();
            }

            cataObject.put(key, value);
            jsonObject.put(cata, cataObject);
            return jsonObject.toJSONString();
        } catch (Throwable e) {
            JSONObject jsonObject = new JSONObject();

            JSONObject cataObject;
            try {
                cataObject = (JSONObject) jsonObject.get(cata);
                if (cataObject == null) {
                    cataObject = new JSONObject();
                }
            } catch (Throwable e2) {
                cataObject = new JSONObject();
            }

            cataObject.put(key, value);
            jsonObject.put(cata, cataObject);
            return jsonObject.toJSONString();
        }
    }

    public static String getExtraInfo(String extraInfo, String key) {
        String result = null;
        try {
            JSONObject jsonObject = (JSONObject) JSON.parse(extraInfo);
            result = jsonObject.get(key).toString();
        } catch (Throwable e) {
            e.printStackTrace();
        }
        return result;
    }


    public static String sendGet(String url, String param) {
        String result = "";
        BufferedReader in = null;
        try {
            String urlNameString = url + "?" + param;
            URL realUrl = new URL(urlNameString);
            // 打开和URL之间的连接
            URLConnection connection = realUrl.openConnection();
            // 设置通用的请求属性
            connection.setRequestProperty("accept", "*/*");
            connection.setRequestProperty("connection", "Keep-Alive");
            connection.setRequestProperty("user-agent",
                    "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
            // 建立实际的连接
            connection.connect();
            // 获取所有响应头字段
            Map<String, List<String>> map = connection.getHeaderFields();
            // 遍历所有的响应头字段
            for (String key : map.keySet()) {
                System.out.println(key + "--->" + map.get(key));
            }
            // 定义 BufferedReader输入流来读取URL的响应
            in = new BufferedReader(new InputStreamReader(
                    connection.getInputStream()));
            String line;
            while ((line = in.readLine()) != null) {
                result += line;
            }
        } catch (Exception e) {
            System.out.println("发送GET请求出现异常！" + e);
            e.printStackTrace();
        }
        // 使用finally块来关闭输入流
        finally {
            try {
                if (in != null) {
                    in.close();
                }
            } catch (Exception e2) {
                e2.printStackTrace();
            }
        }
        return result;
    }

    /**
     * 向指定 URL 发送POST方法的请求
     *
     * @param url
     *            发送请求的 URL
     * @param param
     *            请求参数，请求参数应该是 name1=value1&name2=value2 的形式。
     * @return 所代表远程资源的响应结果
     */
    public static String sendPost(String url, String param) {
        PrintWriter out = null;
        BufferedReader in = null;
        String result = "";
        try {
            URL realUrl = new URL(url);
            // 打开和URL之间的连接
            URLConnection conn = realUrl.openConnection();
            // 设置通用的请求属性
            conn.setRequestProperty("accept", "*/*");
            conn.setRequestProperty("connection", "Keep-Alive");
            conn.setRequestProperty("user-agent",
                    "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
            // 发送POST请求必须设置如下两行
            conn.setDoOutput(true);
            conn.setDoInput(true);
            // 获取URLConnection对象对应的输出流
            out = new PrintWriter(conn.getOutputStream());
            // 发送请求参数
            out.print(param);
            // flush输出流的缓冲
            out.flush();
            // 定义BufferedReader输入流来读取URL的响应
            in = new BufferedReader(
                    new InputStreamReader(conn.getInputStream()));
            String line;
            while ((line = in.readLine()) != null) {
                result += line;
            }
        } catch (Exception e) {
            System.out.println("发送 POST 请求出现异常！"+e);
            e.printStackTrace();
        }
        //使用finally块来关闭输出流、输入流
        finally{
            try{
                if(out!=null){
                    out.close();
                }
                if(in!=null){
                    in.close();
                }
            }
            catch(IOException ex){
                ex.printStackTrace();
            }
        }
        return result;
    }

    private static SecureRandom random = new SecureRandom();
    public static String randomString(int length) {
        String str = new BigInteger(130, random).toString(32);
        return str.substring(0, length);
    }

    public static String getOrderNo() {
        return new Date().getTime() + randomString(7);
    }

    public static String getRemoteIP(HttpServletRequest request) {
        if (request.getHeader("x-forwarded-for") == null) {
            return request.getRemoteAddr();
        }
        return request.getHeader("x-forwarded-for");
    }

    public static void switchConfig(boolean h5, WxPayService wxPayService, MyConfig config) {
        if (wxPayService != null) {
            wxPayService.getConfig().setAppId(h5 ? "wxfcdb77a8210d27ab" : "wxcea0ee4d16192c35");
        }

        if (config != null) {
            config.setAppID(h5 ? "wxfcdb77a8210d27ab" : "wxcea0ee4d16192c35");
            config.setSecret(h5 ? "a818f87ffa555a93621c17900a477bb5" : "42903a181a4a023c969b68fd9fc05090");
        }
    }

    public static List<Integer> str2intList(String str) {
        return str2intList(str, ",");
    }
    public static List<Integer> str2intList(String str, String regex) {

        List<Integer> intList = null;

        if (str != null && !StringUtils.isEmpty(str)) {
            String[] sl = str.split(regex);
            if (sl.length != 0) {
                intList = new ArrayList<>();
                for (String s : sl) {
                    intList.add(Integer.parseInt(s));
                }
            }
        }
        return intList;
    }

    public static List<String> strToStrList(String str) {
        List<String> list = new ArrayList<>();
        if (Arguments.isEmpty(str)) {
            return list;
        }
        String[] sl = str.split(",");
        if (sl.length == 0) {
            return list;
        }
        list.addAll(Arrays.asList(sl));
        return list;
    }

    public static String randomPwd() {
        Random random = new Random();
        StringBuilder sb = new StringBuilder();
        for (int i = 0; i < 6; i++) {
            sb.append(random.nextInt(10));
        }
        return "yyks" + sb.toString();
    }

    public static String randomName() {
        return "User_" + UUID.randomUUID().toString().substring(0, 7);
    }

    public static String invateCode() {
        return UUID.randomUUID().toString().replaceAll("-", "").substring(0, 6);
    }

    /**
     * 获得n位随机验证码
     *
     * @return
     */
    public static String getRandom(Integer length) {
        String str = "0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ";
        Random random = new Random();
        StringBuilder sb = new StringBuilder();
        for (int i = 0; i < length; i++) {
            sb.append(str.charAt(random.nextInt(str.length())));
        }
        return sb.toString();
    }

    /**
     * 获取两个数之间的随机数
     *
     * @param minCount
     * @param maxCount
     * @return
     */
    public static int getRandom(Integer minCount, Integer maxCount) {
        return new Random().nextInt(maxCount - minCount) + minCount;
    }

//    public static void main(String[] args) {
//        for (int i = 0; i < 1000; i++) {
//            System.out.println(Utility.getRandom(4));
//        }
//    }
}
